package com.catmiao.spark.framework.controller

import com.catmiao.spark.framework.common.TController
import com.catmiao.spark.framework.service.WordCountService
import org.apache.spark.rdd.RDD

/**
 * @title: WordCountController
 * @projectName spark_study
 * @description: TODO
 * @author ChengMiao
 * @date 2024/3/15 15:55
 */
class WordCountController extends TController{

  val service = new WordCountService


  // 调度
  def execute(): Unit = {

    val tuples: Array[(String, Int)] = service.dataAnalysis()

    tuples.foreach(println)
  }

}
